package com.ziroom.crm.mq.core.persistence;

import com.ziroom.crm.mq.core.MqType;
import com.ziroom.crm.mq.core.data.Message;
import com.ziroom.crm.mq.core.data.ProcessTypes;
import lombok.extern.slf4j.Slf4j;

import java.util.Collections;
import java.util.Date;
import java.util.List;

/**
 * <p></p>
 * <p>
 * <PRE>
 * <BR>    修改记录
 * <BR>-----------------------------------------------
 * <BR>    修改日期         修改人          修改内容
 * </PRE>
 *
 * @author WeiShaoying
 * @version 1.0
 * @date Created in 2020年09月03日 16:30
 * @since 1.0
 */
@Slf4j
@SuppressWarnings("ALL")
public class DefaultPersistence implements Persistence {

    @Override
    public String getType() {
        return null;
    }

    @Override
    public MqType getMqType() {
        return null;
    }

    @Override
    public void save(Message message, ProcessTypes processType) {
        //do nothing
    }

    @Override
    public void batchSave(List messageList, ProcessTypes processType) {
        //do nothing
    }

    @Override
    public List queryMessage(int size, ProcessTypes processType, Date queryEndTime) {
        return Collections.emptyList();
    }

    /**
     * 查询所有消息
     *
     * @param processTypes
     * @return
     */
    @Override
    public List queryAllMessage(ProcessTypes... processTypes) {
        return Collections.emptyList();
    }

    /**
     * 清空
     *
     * @param processTypes
     */
    @Override
    public void clear(ProcessTypes... processTypes) {
        log.debug("====DefaultPersistence clear()");
    }

    /**
     * 读取行数
     *
     * @param processTypes
     * @return
     */
    @Override
    public int getDataCount(ProcessTypes... processTypes) {
        return 0;
    }

}
